package com.daykw.xiaohongshu.mq;

import java.util.List;

import org.apache.log4j.Logger;
import org.nutz.dao.Dao;
import org.springframework.stereotype.Service;

import com.daykw.xiaohongshu.model.H2XHSUrls;


public class RepairLocalMQ {
	private static Logger logger = Logger.getLogger(RepairLocalMQ.class);

	public void doStart(Dao h2dao) {

		List<H2XHSUrls> list = h2dao.query(H2XHSUrls.class, null);

		for (H2XHSUrls url : list) {
			// dao.update(TArticleTask.class, Chain.make("send_status", 0),
			// Cnd.where("id", "=", url.getId()));
			// h2dao.delete(H2XHSUrls.class, url.getId());
			//TQueue.getQueue().add(url);
		}
		logger.info("加载本地XHSH2缓存队列 " + list.size() + "个完毕");
	}
}
